package cn.sciento.transfer.infra.repository.impl;

import java.util.List;
import cn.sciento.mybatis.base.impl.BaseRepositoryImpl;
import cn.sciento.transfer.domain.entity.ConsumerEvent;
import cn.sciento.transfer.domain.repository.ConsumerEventRepository;
import cn.sciento.transfer.infra.mapper.ConsumerEventMapper;
import cn.sciento.transfer.infra.rocketmq.vo.MqMessage;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class ConsumerEventRepositoryImpl extends BaseRepositoryImpl<ConsumerEvent> implements ConsumerEventRepository {
  @Autowired
  private ConsumerEventMapper consumerEventMapper;
  
  public List<MqMessage> selectEventsLargeEventId(Long eventId, String service, String table) {
    return this.consumerEventMapper.selectEventsLargeEventId(eventId, service, table);
  }
}
